package tag

import org.apache.spark.sql.Row

object ChannelTags extends Tags {
  override def makeTags(args: Any*): List[(String, Int)] = {
    //获取参数row
    val row = args(0).asInstanceOf[Row]
    //创建list
    var list = List[(String,Int)]()
    val adplatformproviderid = row.getAs[Int]("adplatformproviderid")
    if (adplatformproviderid > 0) {
      list :+= ("CN" + adplatformproviderid, 1)
    }

    list
  }
}
